package com.ww.springboot.rabbitmq.listener;

import org.springframework.amqp.rabbit.connection.CorrelationData;
import org.springframework.amqp.rabbit.core.RabbitTemplate.ConfirmCallback;

/**
 * 描述：1.配置中开启confirm
 * 2.RabbitTemplate 中添加 ConfirmCallback
 * <p>
 * 使用此方法可以实现confirm 及mq消费的每一个消息都会触发此方法 以此来实现消息可靠性
 *
 * @author 🧑 ‍wanwei
 * @since 2023-02-16 17:36
 */
public class ConfirmCallbackImpl implements ConfirmCallback {

    @Override
    public void confirm(CorrelationData correlationData, boolean ack, String cause) {
        System.out.println(correlationData);
        System.out.println(ack);
        System.out.println(cause);
        System.out.println("-------confirm-------");
    }
}
